package org.wyz.observer_after;

public class MqClient implements SubClient {
    @Override
    public void consume(String msg) {
        System.out.println("mq has consume msg...");
    }
}
